//package com.xxx.service;
//
//import org.apache.rocketmq.client.producer.LocalTransactionState;
//import org.apache.rocketmq.client.producer.TransactionListener;
//import org.apache.rocketmq.common.message.MessageExt;
//import org.springframework.stereotype.Service;
//
///**
// * rocketmq事务消息②
// */
//@Service
//public class MyTransactionListener implements TransactionListener {
//
//    public LocalTransactionState executeLocalTransaction(org.apache.rocketmq.common.message.Message message, Object o) {
//        // 执行本地事务，例如：更新数据库等
//        // 根据本地事务执行结果返回事务状态：COMMIT_MESSAGE 或 ROLLBACK_MESSAGE 或 UNKNOW
//        return LocalTransactionState.COMMIT_MESSAGE; // 示例，根据实际业务逻辑返回状态
//    }
//
//    public LocalTransactionState checkLocalTransaction(MessageExt messageExt) {
//        // 检查本地事务状态，例如：查询数据库等
//        return LocalTransactionState.COMMIT_MESSAGE; // 根据实际业务逻辑返回状态
//    }
//}